setwd("../")
rm(list = ls())

# # only need to install once
# devtools::install_github("cloudyr/pyMTurkR", dependencies=TRUE)
# devtools::install_github("Luwei-Ying/validateIt", dependencies=TRUE)
# load R package
library(validateIt)

### load topic model
load('models/stm500k.Rdata')

### prepare tasks
newMass <- combMass(stm500k)
R4WSIstm500k <- validateTopic(type = "R4WSI", n = 500, vocab = newMass[[1]], beta = newMass[[2]], thres = 20)
goldR4WSI <- read.csv("goldstandard/goldR4WSI.csv", stringsAsFactors = FALSE)
R4WSIstm500k <- mixGold(tasks = R4WSIstm500k, golds = goldR4WSI)
R4WSIstm500k <- recordTasks(type = "R4WSI", tasks = R4WSIstm500k,
                           path = "topicrecords/R4WSIstm500k.Rdata")

# ##### interact with Mturk from here #####
# ### environment
# library(pyMTurkR)
# Sys.setenv(AWS_ACCESS_KEY_ID = "AWS_ACCESS_KEY_ID")
# Sys.setenv(AWS_SECRET_ACCESS_KEY = "AWS_SECRET_ACCESS_KEY")
# options(pyMTurkR.sandbox = T) # Change sandbox = F when ready to run on MTurk
# AccountBalance()
# 
# ### send tasks (first trial)
# R4WSIstm500kids <- sendTasks(hit_type = 'find_from_dashboard', hit_layout = 'find_from_dashboard', type = "R4WSI",
#                             tasksrecord = R4WSIstm500k, HITidspath = "HITids/R4WSIstm500kids1.Rdata")
# ### extend HITs if needed
# for(i in R4WSIstm500kids[[1]]){
#   ExtendHIT(hit = i, add.seconds = 60*60*24)
# }
# 
# load("HITids/R4WSIstm500kids1.Rdata")
# R4WSIstm500kresults1 <- getResults(batch_id = "R4WSIstm500k1", hit_ids = HITids, retry = FALSE)
# write.csv(R4WSIstm500kresults1, "../../1_replication/1_topicvalidation/topicresults/R4WSIstm500kresults1.csv", row.names = FALSE)
# evalResults(results = R4WSIstm500kresults1, key = R4WSIstm500k, type = "R4WSI")
# 
# ### send tasks (second trial)
# R4WSIstm500kids <- sendTasks(hit_type = 'find_from_dashboard', hit_layout = 'find_from_dashboard', type = "R4WSI",
#                             tasksrecord = R4WSIstm500k, HITidspath = "HITids/R4WSIstm500kids2.Rdata")
# ### extend HITs if needed
# for(i in R4WSIstm500kids[[1]]){
#   ExtendHIT(hit = i, add.seconds = 60*60*24)
# }
# 
# load("HITids/R4WSIstm500kids2.Rdata")
# R4WSIstm500kresults2 <- getResults(batch_id = "R4WSIstm500k2", hit_ids = HITids, retry = FALSE)
# write.csv(R4WSIstm500kresults2, "../../1_replication/1_topicvalidation/topicresults/R4WSIstm500kresults2.csv", row.names = FALSE)
# evalResults(results = R4WSIstm500kresults2, key = R4WSIstm500k, type = "R4WSI")